package com.li.onjava8.concurrent.es;

import com.li.onjava8.concurrent.es.task.NapTask;

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.stream.IntStream;

/**
 * @author li
 * @date 2023/10/30 14:24
 */
public class SingleThreadExecutor2 {
    public static void main(String[] args) {
        ExecutorService es = Executors.newSingleThreadExecutor();
        IntStream.range(0, 10)
                .mapToObj(NapTask::new)
                .forEach(es::execute);
        es.shutdown();
        //如果你只是调用exec.shutdown()，程序将完成所有任务。也就是说，不需要 while(!exec.isTerminated()）。
    }
}
